package com.athl.demoreactor.reactor8;

import java.util.Observable;

/**
 * @author hl
 * @data 2020/9/16
 * <p>
 * 观察者模式
 */
public class ObserverDemo extends Observable {

    public static void main(String[] args) {
        ObserverDemo observer = new ObserverDemo();
        // 添加观察者
        observer.addObserver((o, arg) -> {
            System.out.println("发生变化");
        });
        observer.addObserver((o, arg) -> {
            System.out.println("收到，发生改变");
        });
        // 数据变化
        observer.setChanged();
        // 通知
        observer.notifyObservers();
    }
}
